package com.zhs;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.common.RemotingHelper;

/**
 启动前先确认已经创建topic_java主题
 创建主题方法：sh mqadmin updateTopic -n 192.168.0.241:9876  -c  rocketmq-cluster -t  topic_java
 */
public class Producer {
    public static void main(String[]args) throws Exception{
        //创建生成者，并制定分组
        DefaultMQProducer producer=new DefaultMQProducer("producer_group");
        //制定nameserver地址
        producer.setNamesrvAddr("192.168.0.241:9876");
        //初始化producer，整个生命周期只调用一次
        producer.start();
        for(int i=0;i<100;i++){
            Message message=new Message(
                    "topic_java", //主题
                    "tagA", //标签
                    ("hello java demo rocketmq "+i).getBytes(RemotingHelper.DEFAULT_CHARSET)  //发送消息内容
            );
            //发送消息返回结果
            SendResult result=producer.send(message);
            System.out.printf("%s%n",result);
        }
        //关闭并清理资源
        producer.shutdown();
    }
}
